package utils.config;

/**
 * 定义一些全局的变量 获取properties中读取的内容
 */
public class MyConfig {
    public static String KAFKA_BOOTSTRAP_SERVER = MyPropsUtils.apply("kafka.bootstrap-servers");
    static String KEY_SERIALIZER_CLASS_CONFIG = MyPropsUtils.apply("keySerializer");
    static String VALUE_SERIALIZER_CLASS_CONFIG = MyPropsUtils.apply("valueSerializer");
    static String ACKS_CONFIG = MyPropsUtils.apply("ackConfig");
    static String ENABLE_IDEMPOTENCE_CONFIG = MyPropsUtils.apply("enable_idempotence_config");


    static String REDIS_HOST = MyPropsUtils.apply("redis.host");
    static int REDIS_PORT = Integer.parseInt(MyPropsUtils.apply("redis.port"));

    static String ES_HOST = MyPropsUtils.apply("es.host");
    static Integer ES_PORT = Integer.parseInt(MyPropsUtils.apply("es.port"));

}
